package com.ibeifeng.senior.kafka.consumer;

import com.ibeifeng.senior.kafka.producer.KafkaProperties;

/**
 * 描述:
 * consumer test
 *
 * @author jiantao7
 * @create 2018-05-10 19:04
 */
public class ConsumerTest {
    public static void main(String[] args) {
        Consumer consumer = new Consumer(KafkaProperties.TOPIC);

        while (KafkaProperties.count < KafkaProperties.MESSAGE_CONSUMER_COUNT+500)
        {
            consumer.doWork();
        }

    }

}